﻿using System;

namespace MicroMq.Services
{
    public class DelayWorkItem : WorkItem
    {
        public DelayWorkItem(string topic, byte[] bytes, int delay, int retryCount) : base(topic, bytes, retryCount)
        {
            ExecuteTime = DateTimeOffset.Now.ToUnixTimeMilliseconds() + delay * 1000;
        }

        /// <summary>
        /// 时间
        /// </summary>
        public long ExecuteTime { get; }
    }
}
